package com.fm.openinstall.e;

import java.util.concurrent.*;

class i implements Runnable
{
    final /* synthetic */ f a;

    i(final f a) {
        this.a = a;
    }

    @Override
    public void run() {
        while (true) {
            if (!this.a.h) {
                return;
            }
            while (true) {
                while (true) {
                    try {
                        this.a.b.poll(10L, TimeUnit.SECONDS);
                        if (this.a.d()) {
                            this.a.e();
                        }
                        break;
                    }
                    catch (InterruptedException ex) {}
                    continue;
                }
            }
        }
    }
}
